package com.edata.bigdata.flink

import org.apache.flink.api.common.typeinfo.TypeInformation

import scala.reflect.ClassTag

object FlinkStreamMatcher {

  def createCEPPatternBuilder[IN: ClassTag, OUT: ClassTag](): PatternBuilder[IN,OUT] = {
    val clazz = implicitly[ClassTag[OUT]].runtimeClass.asInstanceOf[Class[OUT]]
    val ti = TypeInformation.of(clazz)
    new PatternBuilder[IN,OUT]()(ti)
  }
}